package com.young.ums.core;

/**
 * 订阅接口
 * @author imrookie
 * @date 2018/10/14
 */
public interface ISubscriber {
    /**
     * 返回订阅的主题数组
     */
    ETopic[] topics();

    /**
     * 消费
     * @param topic 主题
     * @param message 传输对象
     */
    void consume(ETopic topic, Object message);
}
